package com.example.helloworld.mq.service;

import com.example.helloworld.mq.entity.CanalKafkaMessage;
import com.example.helloworld.mq.entity.KafkaMessage;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;


@Component
public class KafkaConsumer {

    // 监听 test-topic 主题，自动反序列化消息为 Message 对象
//    @KafkaListener(topics = "test-topic", groupId = "test-group")
//    public void consume(Message message, Acknowledgment acknowledgment) {
//        // 处理消息
//        System.out.println("收到消息：" + message);
//
//        // 手动确认消息（若配置了 ack-mode: manual_immediate）
//        acknowledgment.acknowledge();
//    }

    // 监听 example 主题，自动反序列化消息为 CanalKafkaMessage 对象
    @KafkaListener(topics = "example")
    public void consumeExample(CanalKafkaMessage message, Acknowledgment acknowledgment) {
        // 处理消息
        System.out.println("收到example主题消息：" + message);

        // 手动确认消息（若配置了 ack-mode: manual_immediate）
        acknowledgment.acknowledge();
    }
}
